//package com.yasaka.stock.kafkaConsumer;
//
//import org.apache.kafka.clients.consumer.ConsumerRecord;
////import org.springframework.kafka.annotation.KafkaListener;
//import org.springframework.stereotype.Component;
//
//import java.util.Optional;
//
///**
// * @author Roger.Xie
// * @date 2018/8/13
// **/
//@Component
//public class KafkaConsumerListener {
//
//    /**
//     * 这里使用正则匹配topic，其中【*】之前得加上【.】才能匹配到。
//     *
//     * @param record
//     */
//    @KafkaListener(topicPattern = "sdptopic.*")
//    public void listener(ConsumerRecord<String, String> record) {
//        Optional<String> kafkaMessage = Optional.ofNullable(record.value());
//        if (kafkaMessage.isPresent()) {
//            System.out.println("topic : {" + record.topic() + "}, mes : {" + kafkaMessage.get() + "}");
//        }
//    }
//}
